package com.bjtu.boatmq.client.producer;

import java.util.List;

import com.bjtu.boatmq.common.protocol.Message;

public interface MQProducer {
	void createTopic(String newTopic, int partitionNum,int backupNum);
	void createTopic(String newTopic);
	void createTopic(String newTopic, int partitionNum);
	void start();
	void shutdown();
	void send(List<Message> msg);
}
